package sample;

import reactor.core.publisher.FluxSink;
import reactor.core.publisher.UnicastProcessor;

public class ProcessorsDemo {
    public static void main(String[] args) {
        UnicastProcessor<Integer> processor = UnicastProcessor.create();
        FluxSink<Integer> sink = processor.sink(FluxSink.OverflowStrategy.DROP);
        // 多个生产者线程可以并发地生成数据到以下的序列化 sink。
//        sink.next(n);

    }
}
